package com.seekting.demo;

import rx.Observable;
import rx.functions.Action1;
import rx.functions.Func1;

/**
 * Created by Administrator on 2017/12/15.
 */

public class MyObserver {

    public static void main(String args[]) {

        Observable.just("11").map(new Func1<String, Integer>() {
            @Override
            public Integer call(String s) {
                return Integer.valueOf(s);
            }
        }).subscribe(new Action1<Integer>() {
            @Override
            public void call(Integer integer) {

                System.out.println("integer=" + integer);

            }
        });
    }

    private static <T> void subscribePrint(Observable<T> observable, String name) {



    }
}
